package com.achao.achaomq.service;

/**
 * RocketMQ发送与消费消息封装
 */
public interface RocketMqService {

    /**
     * 发送rocketMQ消息
     *  @param rvo
     *  @param topic
     *  @param remark
     */
    void sendRocketMQ(Object rvo,String topic,String remark);

}
